package com.xuecheng.messagesdk.service;

import com.xuecheng.messagesdk.model.MqMessageDo;
import com.xuecheng.messagesdk.model.po.MqMessage;
import com.baomidou.mybatisplus.extension.service.IService;

import java.util.List;

/**
 * <p>
 *  服务类
 * </p>
 *
 * @author itcast
 * @since 2024-08-31
 */
public interface MqMessageService extends IService<MqMessage> {

    void saveMessage(MqMessageDo mqMessageDo);

    List<MqMessage> getWaitTaskList(Integer shardIndex, Integer shardTotal, Integer total);

    void updateStageState(Integer num, Long id);
}
